package com.example.rxbyhand;

/**
 * Author by lp,on 2021/8/16/016,17:42.
 */
public  abstract class AbstractObservanleWithUpStream<T,U> extends Observable<U> {
    protected final  ObservableSource<T> source;

    protected AbstractObservanleWithUpStream(ObservableSource<T> source) {
        this.source = source;
    }
}
